package com.ysd.dao.Impl;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.mysql.jdbc.Statement;
import com.ysd.entity.Product;
import com.ysd.util.DBManager;

public class ProductDaoImpl {
	//根据分类Id查询对应的产品列表，cId产品分类Id
     public List<Product> getProductsList(int cId){//什么情况下有参数？一般看sql语句有没有条件
    	 List<Product> productList=new ArrayList<Product>();
    	 Connection conn=DBManager.getConnection();//建立连接
    	 Statement st=null;
    	 ResultSet rs=null;
    	 try {//正常情况下
    		 st=(Statement) conn.createStatement();//创建statement对象
    		 rs=st.executeQuery("SELECT * FROM product WHERE productCatalogueId="+cId);//执行查询
    		 while(rs.next()) {//遍历结果集
    			 int productId=rs.getInt("productId");
    			 String productName=rs.getString("productName");
    			 String productImg=rs.getString("productImg");
    			 Product product=new Product(productId,productName,productImg);
    			 productList.add(product);
    		 }
    		 return productList;//正常下返回产品集合
		} catch (SQLException e) {//异常情况下
			e.printStackTrace();
			return null;//异常情况下返回空
		}finally {//关闭流
			DBManager.closeAll(conn, st, rs);
		}
    	 
     }
}
